package com.learning.rocketmq.springbootclient.springboot;

import org.rocketmq.starter.annotation.RocketMQListener;
import org.rocketmq.starter.annotation.RocketMQMessage;
import org.springframework.stereotype.Service;

/**
 * ClassName: ConsumerServiceBoot
 * Description:
 * Date: 2019/1/15 14:10 【需求编号】
 *
 * @author Sam Sho
 * @version V1.0.0
 */
@Service
public class ConsumerServiceBoot {


    @RocketMQListener(topic = "", consumerGroup = "")
    public class Consumer1 {


        @RocketMQMessage(tag = "tagA", messageClass = String.class)
        public String consumerTagA() {
            return "";
        }

        @RocketMQMessage(tag = "tagB", messageClass = String.class)
        public String consumerTagB() {
            return "";
        }
    }
}
